# -*- coding: utf-8 -*-
# standard
import os
import sys

# third

# local
_P_PATH =  os.path.dirname(os.path.dirname(os.path.realpath(__file__)))
if _P_PATH not in sys.path:
    sys.path.append(_P_PATH)
from models.callbacks import *
from models.json_files import *
from models.scp_files import *
from models.csv_model import *


"""
@Title:  模型模块
@File: __init__.py
@Author: walle 2023年10日18日 11时44分48秒
@Version: 1.0.0
@Desc: 
"""


# Base.metadata.tables['video_download_url'].drop(engine)
# Base.metadata.tables['raw_json_parse_record'].drop(engine)
# Base.metadata.tables['raw_video_object'].drop(engine)
Base.metadata.create_all(engine)



if __name__ == '__main__':
    good_files, bad_files = ScpRecordOrm.view_remote_files()  # 查看存储服务器上的文件信息
    print(f"远程服务商有号文件{len(good_files)} {'坏文件' + str(len(bad_files)) + '个' if len(bad_files) > 0 else ''}")
    # RawVideoObjectOrm.get_all_videos_from_db()
    pass
